package com.lds.memory.kafka.partition.selector;

public class HashPartitionSelector implements IPartitionSelector {
    @Override
    public int select(int partitionCount, String partitionKey) {
        return partitionKey.hashCode() % partitionCount;
    }

}
